f0370f4b01a4d3a03532c2f82130574f2894a358,protocol/src/main/java/org/jboss/as/protocol/ProtocolChannelClient.java,ProtocolChannelClient,connectSync,#CallbackHandler#Map#,131
Before Change
public Connection connectSync(CallbackHandler handler, Map<String, String> saslOptions) throws IOException {
final IoFuture<Connection> future = connect(handler, saslOptions);
final IoFuture.Status status = future.await(configuration.getConnectionTimeout(), TimeUnit.MILLISECONDS);
if(status == IoFuture.Status.DONE) {
return future.get();
}
After Change
public Connection connectSync(CallbackHandler handler, Map<String, String> saslOptions) throws IOException {
WrapperCallbackHandler wrapperHandler = new WrapperCallbackHandler(handler);
final IoFuture<Connection> future = connect(wrapperHandler, saslOptions);
long timeoutMillis = configuration.getConnectionTimeout();
IoFuture.Status status = future.await(timeoutMillis, TimeUnit.MILLISECONDS);
while (status == IoFuture.Status.WAITING) {
if (wrapperHandler.isInCall()) {
// If there is currently an interaction with the user just wait again.
status = future.await(timeoutMillis, TimeUnit.MILLISECONDS);